package com.stu.vertx.hello.vertxDemo.点对点;
 
import io.vertx.core.AbstractVerticle;
import io.vertx.core.eventbus.EventBus;

public class Comsumer extends AbstractVerticle {
    @Override
    public void start() throws Exception {
        EventBus bus = vertx.eventBus();
        bus.consumer("my.update",res -> {
            String resBody =(String) res.body();
            System.out.println("Comsumer"+ resBody);
        });
    }
}